class DB {
  constructor(){
      this.mysql = require('mysql')
      this.dbConfig = require('./db.config.js')
  }
  query(sql,params){
      return new Promise((resolve,reject) => {
          //1.创建mysql连接对象
          const con = this.mysql.createConnection(this.dbConfig)

          //开启连接
          con.connect((err) => {
              if(err){
                  console.log('数据库连接失败')
                  reject(err)
              }else{
                  console.log('数据库连接成功')
              }
          })

          //3.执行sql查询语句
          con.query(sql,params,(err,results) => {
              if(err){
                  console.log('查询语言操作失败')
                  reject(err)
              }else{
                  console.log('查询语言操作成功')
                  resolve({results})
              }
          })

          //4.关闭数据库
          con.end((err) => {
              if(err){
                  console.log('数据库关闭失败')
                  reject(err)
              }else{
                  console.log('数据库关闭成功')
              }
          })
      })
  }
}

module.exports = new DB()